package com.v5.java.rpc.server;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import org.apache.hadoop.ipc.RPC.Server;

public class MyRPCServer {

	public static void main(String[] args) throws Exception {
		// 使用HDFS的RPC Server来部署我们的程序
		RPC.Builder builder = new RPC.Builder(new Configuration());

		builder.setBindAddress("localhost");
		builder.setPort(7788);

		// 部署我们的程序
		builder.setProtocol(MyBusiness.class);// 部署接口
		builder.setInstance(new MyBusinessImpl());// 定义接口实现，客户端调用的时候，需要指定相同的签名

		// 生成RPC Server
		Server server = builder.build();
		server.start();
	}

}
